package com.woniuxy.email;

import org.junit.jupiter.api.Test;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;

/**
 * @author yellow Docter
 * @date 2024-10-23
 * @desc 蜗牛创想：www.woniuxy.com
 *   测试 消费者的 消息确认机制
 */
@SpringBootTest   //创建IOC容器
public class MQTest05 {

    //IOC   控制反转
    //DI    依赖注入

    //这里才可以注入
    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    public void send01(){
        String exchange = "confirm.exchange";
        String  key = "woniuxy.gz";
        String msg = "腾讯和蜗牛达成战略学习355";

        // 正常测试：为消息指定一个唯一的CorrelationData对象，以便在确认回调时可以关联到具体的消息
        rabbitTemplate.convertAndSend(
                exchange,
                key,
                msg,
                new CorrelationData("c444"));

    }
}
